#!/usr/bin/python
#-*- coding: UTF-8 -*-

from sqlalchemy import create_engine
from mconfig import MServerConfig


mysql_engine = create_engine("mysql://%s:%s@%s/%s?charset=utf8" % (MServerConfig['USER'],MServerConfig['PASSWORD'],MServerConfig['DB_SERVER'],MServerConfig['DB']),echo=MServerConfig['DB_DEBUG'],pool_recycle=3600)
connection = mysql_engine.connect()

#在数据库中生成表
#Base.metadata.create_all(engine) 

from sqlalchemy.orm import sessionmaker

#创建了一个自定义了的 Session类,#将创建的数据库连接关联到这个session
Session = sessionmaker(bind=mysql_engine)
session = Session()

#regos = RegisterOs('123123','122.1.1.1')

#session.add(regos)  #在session中添加内容
 
#session.flush() #保存数据
#session.commit() #数据库事务的提交,sisson自动过期而不需要关闭
#query = session.query(RegisterOs) #query() 简单的理解就是select() 的支持 ORM 的替代方法,可以接受任意组合的 class/column 表达式
#print list(query) #列出所有user
#print query.get(1) #根据主键显示



#session.add(ed_user)
#session.add_all([
    #User('wendy', 'Wendy Williams', 'foobar'),
    #User('mary', 'Mary Contrary', 'xxg527'),
    #User('fred', 'Fred Flinstone', 'blah')])


#print query.filter_by(user_name='dongwm').first()  #类似于SQL的where,打印其中的第一个
#u = query.filter_by(user_name='dongwm').first()
#u.password = 'newpass' #修改其密码字段
#session.commit() #提交事务
#print query.get(1).password #打印会出现新密码
 
#for instance in session.query(User).order_by(User.id):  #根据id字段排序,打印其中的用户名和邮箱地址
#    print instance.user_name, instance.email_address


#lb_name = 'test'
            
##更新备份实例ID的数据
#query = session.query(AWSMonitorLBInstanceBak)

##count为删除的记录数
#count = query.filter_by(lb_name=lb_name).delete()

#session.commit()